471938238e56b52e8291c537655092fd8bfe47c9,src/java/org/apache/cassandra/streaming/StreamInSession.java,StreamInSession,closeIfFinished,#,125
Before Change
assert sstable.getTableName().equals(table);
// Acquiring the reference (for secondary index building) before adding it makes sure we don't have to care about races
sstable.acquireReference();
referenced.add(sstable);
ColumnFamilyStore cfs = Table.open(sstable.getTableName()).getColumnFamilyStore(sstable.getColumnFamilyName());
After Change
assert sstable.getTableName().equals(table);
// Acquiring the reference (for secondary index building) before adding it makes sure we don't have to care about races
if (!sstable.acquireReference())
throw new RuntimeException("We shouldn't fail acquiring a reference on a sstable that has just been transfered");
referenced.add(sstable);